package com.y2020.d0609;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * @author 歪大哥😁
 * @date 2020-06-09.
 */
public class ProdConsumerTest {







}



class MyResource {

    private volatile boolean openFlag = true;

    private AtomicInteger count = new AtomicInteger(0);

    BlockingQueue<String> queue;

    public MyResource(BlockingQueue<String> queue) {
        this.queue = queue;
        System.out.println("当前入参队列为:" + queue.getClass().getName());
    }




}
